// 聊天室的后端部分，使用第三方的ws模块

const WebSocket = require("ws");

// 创建一个websocket实例，并且将服务创建在8080端口上
const wss = new WebSocket.Server({ port: 8080 });

// 监听客户端的连接,只要由客户连接进来，就会触发后面的回调函数
wss.on("connection", function connection(ws) {
  // ws表示的是连接进来的那一个客户
  // 监听那个用户发来信息
  ws.on("message", function message(data, isBinary) {
    // data表示发过来的信息
    // console.log(data + "");
    // ws.send(data + "");

    // wss.clients表示当前这个服务连接的所有人
    wss.clients.forEach(function each(client) {
      if (client.readyState === WebSocket.OPEN) {
        client.send(data, { binary: isBinary });
      }
    });
  });

  // send方法是向前端发送信息
  // ws.send("something");
});
